package com.bindatax.core.task.segment;

import com.bindatax.core.task.DataTask;

import java.util.concurrent.ArrayBlockingQueue;

public class SegmentData {
    public DataTask parent;
    public String connKey;
    public String sql;
    public volatile SegmentStatus status = SegmentStatus.NON_EXECUTION;
    public ArrayBlockingQueue<Object[]> allSegmentDataQueue;//公共数据队列
    public Exception errorException;
}
